# coding:utf-8


from celery import Celery

try:
    import schedule_env   # 请勿删除
except:
    pass

celery_app = Celery(
    'opc_celery',
    include=[
        'common.schedule.wx_tasks',
        'common.schedule.im_tasks',
        'common.schedule.opc_tasks',
        'common.schedule.demand_task',
        'common.schedule.seven_moor_tasks',
        'common.schedule.new_seven_moor_tasks',
        'common.schedule.demand_bid_task',
        'common.schedule.robot_task',
        'common.schedule.red_packet_tasks'
    ]
)

celery_app.config_from_object('common.schedule.config')

if __name__ == '__main__':
    celery_app.start()
